package com.gopay.common.mq.destination;

import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;

import javax.jms.Destination;

/**
 * 消息通道
 * 定义规范 ： 项目简写_功能
 * @author
 * @date 20161027
 */
public class Destinations {

    /**
     * 风控人工审核通过继续交易， 短信发送通道
     */
    public static Destination RC_AUDIT_PASS_SMS_QUEUE = new ActiveMQQueue("RC_AUDIT_PASS_SMS_QUEUE");

    /**
     * 反诈骗下行指令通道
     */
    public static Destination AF_DOWNSTREAM_QUEUE = new ActiveMQQueue("AF_DOWNSTREAM_QUEUE");

    /**
     * 反诈骗上行反馈指令通道
     */
    public static Destination AF_UPSTREAM_QUEUE = new ActiveMQQueue("AF_UPSTREAM_QUEUE");

    /**
     * 反诈骗主动上报指令通道
     */
    public static Destination AF_REPORT_QUEUE = new ActiveMQQueue("AF_REPORT_QUEUE");

    /**
     * 账户动态查询反馈指令——A00306
     */
    public static Destination AF_DYNAMIC_ACCT_QUEUE = new ActiveMQQueue("AF_DYNAMIC_ACCT_QUEUE");

    public static Destination SMS_MASS_SEND_QUEUE = new ActiveMQQueue("SMS_MASS_SEND_QUEUE");

    /**
     * 风控准实时队列
     */
    public static Destination RC_NEAR_TIME = new ActiveMQQueue("RC_NEAR_TIME");

    /**
     * 异步导出文件任务取消发布
     */
    public static Destination ASYNC_EXPORT_CANCEL_TOPIC = new ActiveMQTopic("ASYNC_EXPORT_CANCEL_TOPIC");
}
